//package net.qhzw.vip.qiyu.listener;
//
//import lombok.extern.slf4j.Slf4j;
//import net.qhzw.vip.qiyu.conf.RabbitmqConfig;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.stereotype.Component;
//
//import java.time.LocalDateTime;
//
//
//@Component
//@Slf4j
//public class OrderReceiver {
//
//    /**
//     * 监听死信队列A
//     * @param message 接收的信息
//     */
//    //@RabbitListener(queues = "dead_letter_queue_a")
//    @RabbitListener(queues = RabbitmqConfig.QUEUE_REPORT_OVERTIME)
//    public void receiveA(Message message) {
//        String msg = new String(message.getBody());
//        System.out.println("监听死信队列A ,当前时间：" + LocalDateTime.now() + "，死信队列A收到的消息：" + msg);
//    }
//
//
//    /**
//     * 监听死信队列B
//     * @param message 接收的信息
//     */
//    @RabbitListener(queues = RabbitmqConfig.QUEUE_ORDER_TIMEOUT)
//    public void receiveB(Message message) {
//        String msg = new String(message.getBody());
//        // 记录日志
//        System.out.println("监听死信队列B ,当前时间：" + LocalDateTime.now() + "，死信队列B收到的消息：" + msg);
//    }
//
//
//}
